const socketIO = require('socket.io'); // 即时通讯
var emitter = require('../utils/events');

exports.socket = function (server) {
  const io = socketIO(server);
  io.on('connection', socket => {
    // 监听处理数据条数
    emitter.addListener('number_event', length => {
      socket.emit('everyMsg', length);
    });
    // 监听搜索页信息
    emitter.addListener('search_event', url => {
      socket.emit('searchMsg', url);
    });
    // 监听错误信息
    emitter.addListener('error_event', url => {
      socket.emit('errorMsg', url);
    });
    // 备份数据成功
    emitter.addListener('backup_event', message => {
      socket.emit('backupMsg', message);
    });
    // 监听所有处理完成
    emitter.addListener('success_event', message => {
      socket.emit('successMsg', message);
    });
    // 监听写入文件事件
    emitter.addListener('write_event', message => {
      socket.emit('writeMsg', message);
    });

    // -----------------------------------------------------

    // 监听错误信息
    // emitter.addListener('findUrl_event', url => {
    //   socket.emit('errorMsg', url);
    // });
    // // 监听所有处理完成
    // emitter.addListener('allSuccess_event', message => {
    //   socket.emit('allSuccessMsg', message);
    // });
    // // 监听写入文件事件
    // emitter.addListener('write_event', message => {
    //   socket.emit('writeMsg', message);
    // });
  });
};
